#include "../mqserver/mq_channel.hpp"

int main()
{
    csjmq::ChannelManager::ptr cmp = std::make_shared<csjmq::ChannelManager>();
    cmp->openChannel("cid1", muduo::net::TcpConnectionPtr(), csjmq::ProtobufCodecPtr(),
                     std::make_shared<csjmq::ConsumerManager>(),
                     std::make_shared<csjmq::VirtualHost>("host1", "./data/host1/message/", "./data/host1/host1.db"),
                     csjmq::ThreadPool::ptr());

    return 0;
}